package com.lichao.utils;

import java.io.FileInputStream;
import java.io.InputStream;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Properties;
import java.util.Set;

public class ReadProperties {
    public static String MYSql1;
    public static String MYSql2;
    public static String MYSql3;

    public static Set<String> tableSet = new HashSet<>();

    public static void init() throws Exception {
        Properties properties = new Properties();
        InputStream inputStream = new FileInputStream("Flink/src/main/resources/application.properties");
        properties.load(inputStream);
        MYSql1 = properties.getProperty("mysql1.url");
        MYSql2 = properties.getProperty("mysql1.url");
        MYSql3 = properties.getProperty("mysql1.url");

        tableSet.add("test1");
        tableSet.add("test2");
        tableSet.add("test3");
    }


}
